import os

from celery import Celery

# 1.celery　是一个即插即用的异步任务,celery运行的时候需要使用到django的setting文件
# 所以我们需要在celery　运行的时候去配置一下
# 第一种方式
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "mall.settings")

# 2.我们需要创建　celery对象
# 第一个参数:main
#　习惯上设置脚本名
app = Celery("celery_tasks")


# 3.设置中间人
# 路径
app.config_from_object("celery_tasks.config")



# 4. celery自动检测任务
# 列表中的元素就是　任务的包路径
app.autodiscover_tasks(["celery_tasks.sms","celery_tasks.email"])

# 5.worker
# 我们的worker其实是一条指令,这条指令需要在　虚拟环境中执行


# celery -A 文件路径.celery实例对象文件　worker -l info
# celery -A celery_tasks.main worker -l info






